🎖️GitЯра🎖️
Node / meshtastic / Meshtastic-Android / files / core / network / src / androidHostTest / kotlin / org / meshtastic / core / network / radio / SerialRadioTransportTest.kt
Displaying Raw • Download
core/network/src/androidHostTest/kotlin/org/meshtastic/core/network/radio/SerialRadioTransportTest.kt bd2863243bab6eb213401d949839a2bc74dde7e2 (bd286324) Text, 22.19 KB
T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.network.radio
Tff7b72import T7ee787com.hoho.android.usbserial.driver.UsbSerialDriver
Tff7b72import T7ee787dev.mokkery.MockMode
Tff7b72import T7ee787dev.mokkery.answering.calls
Tff7b72import T7ee787dev.mokkery.answering.throws
Tff7b72import T7ee787dev.mokkery.every
Tff7b72import T7ee787dev.mokkery.matcher.any
Tff7b72import T7ee787dev.mokkery.mock
Tff7b72import T7ee787dev.mokkery.verify
Tff7b72import T7ee787dev.mokkery.verify.VerifyMode.Companion.exactly
Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope
Tff7b72import T7ee787kotlinx.coroutines.Dispatchers
Tff7b72import T7ee787kotlinx.coroutines.SupervisorJob
Tff7b72import T7ee787kotlinx.coroutines.cancel
Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow
Tff7b72import T7ee787kotlinx.coroutines.runBlocking
Tff7b72import T7ee787kotlinx.coroutines.test.runTest
Tff7b72import T7ee787org.meshtastic.core.network.repository.SerialConnection
Tff7b72import T7ee787org.meshtastic.core.network.repository.SerialConnectionListener
Tff7b72import T7ee787org.meshtastic.core.repository.RadioTransportCallback
Tff7b72import T7ee787java.util.concurrent.CountDownLatch
Tff7b72import T7ee787java.util.concurrent.Executors
Tff7b72import T7ee787java.util.concurrent.TimeUnit
Tff7b72import T7ee787java.util.concurrent.TimeoutException
Tff7b72import T7ee787kotlin.test.Test
Tff7b72import T7ee787kotlin.test.assertEquals
Tff7b72import T7ee787kotlin.test.assertFailsWith
Tff7b72import T7ee787kotlin.test.assertFalse
Tff7b72import T7ee787kotlin.test.assertSame
Tff7b72import T7ee787kotlin.test.assertTrue
Tff7b72class T56d364SerialRadioTransportTest Tb4b4b4{
Tff7b72private Tff7b72val Te6edf3callbackTb4b4b4: Te6edf3RadioTransportCallback Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3serialDriverTb4b4b4: Te6edf3UsbSerialDriver Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3serialConnectionTb4b4b4: Te6edf3SerialConnection Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3serialConnectionListenerTb4b4b4: Te6edf3SerialConnectionListener
Tff7b72private Tff7b72var Te6edf3requestedDriverTb4b4b4: Te6edf3UsbSerialDriver? Tff7b72= Tff7b72null
Tff7b72private Tff7b72fun Td2a8ffcreateTransportTb4b4b4(Te6edf3addressTb4b4b4: Tffa657StringTb4b4b4, Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4)Tb4b4b4: Te6edf3SerialRadioTransport Tb4b4b4{
Te6edf3requestedDriver Tff7b72= Tff7b72null
Tff7b72return Te6edf3SerialRadioTransportTb4b4b4(
Te6edf3callback Tff7b72= Te6edf3callbackTb4b4b4,
Te6edf3scope Tff7b72= Te6edf3scopeTb4b4b4,
Te6edf3serialDevices Tff7b72= Te6edf3MutableStateFlowTb4b4b4(Te6edf3mapOfTb4b4b4(Te6edf3address Te6edf3to Te6edf3serialDriverTb4b4b4)Tb4b4b4)Tb4b4b4,
Te6edf3createSerialConnection Tff7b72= Tb4b4b4{ Te6edf3driverTb4b4b4, Te6edf3listener Tff7b72-Tff7b72>
Te6edf3requestedDriver Tff7b72= Te6edf3driver
Te6edf3serialConnectionListener Tff7b72= Te6edf3listener
Te6edf3serialConnection
Tb4b4b4}Tb4b4b4,
Te6edf3address Tff7b72= Te6edf3addressTb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72fun Td2a8ffcreateRecordingTransportTb4b4b4(
Te6edf3addressTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3connectionsTb4b4b4: Te6edf3MutableListTff7b72<Te6edf3RecordingSerialConnectionTff7b72>Tb4b4b4,
Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4,
Te6edf3devicesTb4b4b4: Te6edf3MapTff7b72<Tffa657StringTb4b4b4, Te6edf3UsbSerialDriverTff7b72> Tff7b72= Te6edf3mapOfTb4b4b4(Te6edf3address Te6edf3to Te6edf3serialDriverTb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3SerialRadioTransport Tb4b4b4{
Te6edf3requestedDriver Tff7b72= Tff7b72null
Tff7b72return Te6edf3SerialRadioTransportTb4b4b4(
Te6edf3callback Tff7b72= Te6edf3callbackTb4b4b4,
Te6edf3scope Tff7b72= Te6edf3scopeTb4b4b4,
Te6edf3serialDevices Tff7b72= Te6edf3MutableStateFlowTb4b4b4(Te6edf3devicesTb4b4b4)Tb4b4b4,
Te6edf3createSerialConnection Tff7b72= Tb4b4b4{ Te6edf3driverTb4b4b4, Te6edf3listener Tff7b72-Tff7b72>
Te6edf3requestedDriver Tff7b72= Te6edf3driver
Te6edf3RecordingSerialConnectionTb4b4b4(Te6edf3listenerTb4b4b4)Tb4b4b4.Te6edf3alsoTb4b4b4(Te6edf3connectionsTff7b72::Te6edf3addTb4b4b4)
Tb4b4b4}Tb4b4b4,
Te6edf3address Tff7b72= Te6edf3addressTb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72fun Td2a8ffassertRequestedDriverTb4b4b4(Te6edf3expectedTb4b4b4: Te6edf3UsbSerialDriver Tff7b72= Te6edf3serialDriverTb4b4b4) Tb4b4b4{
Te6edf3assertSameTb4b4b4(Te6edf3expectedTb4b4b4, Te6edf3requestedDriverTb4b4b4, Ta5d6ff"Ta5d6ffserial connection factory must receive the selected driverTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`failed connection is not left admitted`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3throws Te6edf3IllegalStateExceptionTb4b4b4(Ta5d6ff"Ta5d6ffconnect failedTa5d6ff"Tb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createTransportTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3backgroundScopeTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72falseTb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3callbackTb4b4b4.Te6edf3onDisconnectTb4b4b4(Te6edf3isPermanent Tff7b72= Tff7b72falseTb4b4b4, Te6edf3errorMessage Tff7b72= Ta5d6ff"Ta5d6ffconnect failedTa5d6ff"Tb4b4b4, Te6edf3reason Tff7b72= Tff7b72nullTb4b4b4)
Tb4b4b4}
Te6edf3assertFalseTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`send is rejected promptly while connection is still opening`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runBlockingTff7b72<Tffa657UnitTff7b72> Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Tff7b72val Te6edf3connectEntered Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Tff7b72val Te6edf3releaseConnect Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls
Tb4b4b4{
Te6edf3connectEnteredTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3checkTb4b4b4(Te6edf3releaseConnectTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)
Te6edf3serialConnectionListenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tff7b72val Te6edf3transportScope Tff7b72= Te6edf3CoroutineScopeTb4b4b4(Te6edf3SupervisorJobTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3DispatchersTb4b4b4.Te6edf3DefaultTb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createTransportTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3transportScopeTb4b4b4)
Tff7b72val Te6edf3executor Tff7b72= Te6edf3ExecutorsTb4b4b4.Te6edf3newFixedThreadPoolTb4b4b4(T79c0ff2Tb4b4b4)
Tff7b72try Tb4b4b4{
Tff7b72val Te6edf3startFuture Tff7b72= Te6edf3executorTb4b4b4.Te6edf3submit Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3assertTrueTb4b4b4(
Te6edf3connectEnteredTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffconnect should enter the blocking openTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tff7b72val Te6edf3sendFuture Tff7b72= Te6edf3executorTb4b4b4.Te6edf3submitTff7b72<Tffa657BooleanTff7b72> Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4}
Te6edf3assertFalseTb4b4b4(
Te6edf3sendFutureTb4b4b4.Te6edf3getTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffan opening transport must reject promptlyTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3releaseConnectTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3startFutureTb4b4b4.Te6edf3getTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Tb4b4b4} Tff7b72finally Tb4b4b4{
Te6edf3releaseConnectTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3transportScopeTb4b4b4.Te6edf3cancelTb4b4b4(Tb4b4b4)
Te6edf3executorTb4b4b4.Te6edf3shutdownNowTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`close orders against connection creation before publication`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runBlockingTff7b72<Tffa657UnitTff7b72> Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Tff7b72val Te6edf3creationEntered Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Tff7b72val Te6edf3releaseCreation Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Tff7b72val Te6edf3transportScope Tff7b72= Te6edf3CoroutineScopeTb4b4b4(Te6edf3SupervisorJobTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3DispatchersTb4b4b4.Te6edf3DefaultTb4b4b4)
Tff7b72var Te6edf3factoryDriverTb4b4b4: Te6edf3UsbSerialDriver? Tff7b72= Tff7b72null
Tff7b72val Te6edf3transport Tff7b72=
Te6edf3SerialRadioTransportTb4b4b4(
Te6edf3callback Tff7b72= Te6edf3callbackTb4b4b4,
Te6edf3scope Tff7b72= Te6edf3transportScopeTb4b4b4,
Te6edf3serialDevices Tff7b72= Te6edf3MutableStateFlowTb4b4b4(Te6edf3mapOfTb4b4b4(Te6edf3address Te6edf3to Te6edf3serialDriverTb4b4b4)Tb4b4b4)Tb4b4b4,
Te6edf3createSerialConnection Tff7b72= Tb4b4b4{ Te6edf3driverTb4b4b4, Te6edf3listener Tff7b72-Tff7b72>
Te6edf3factoryDriver Tff7b72= Te6edf3driver
Te6edf3serialConnectionListener Tff7b72= Te6edf3listener
Te6edf3creationEnteredTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3checkTb4b4b4(Te6edf3releaseCreationTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)
Te6edf3serialConnection
Tb4b4b4}Tb4b4b4,
Te6edf3address Tff7b72= Te6edf3addressTb4b4b4,
Tb4b4b4)
Tff7b72val Te6edf3executor Tff7b72= Te6edf3ExecutorsTb4b4b4.Te6edf3newFixedThreadPoolTb4b4b4(T79c0ff2Tb4b4b4)
Tff7b72try Tb4b4b4{
Tff7b72val Te6edf3startFuture Tff7b72= Te6edf3executorTb4b4b4.Te6edf3submit Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3assertTrueTb4b4b4(Te6edf3creationEnteredTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)
Tff7b72val Te6edf3closeFuture Tff7b72= Te6edf3executorTb4b4b4.Te6edf3submit Tb4b4b4{ Te6edf3runBlocking Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}
Te6edf3assertFailsWithTff7b72<Te6edf3TimeoutExceptionTff7b72> Tb4b4b4{ Te6edf3closeFutureTb4b4b4.Te6edf3getTb4b4b4(Te6edf3NOT_YET_WINDOW_MSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3MILLISECONDSTb4b4b4) Tb4b4b4}
Te6edf3releaseCreationTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3startFutureTb4b4b4.Te6edf3getTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)
Te6edf3closeFutureTb4b4b4.Te6edf3getTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)
Te6edf3assertSameTb4b4b4(Te6edf3serialDriverTb4b4b4, Te6edf3factoryDriverTb4b4b4, Ta5d6ff"Ta5d6ffserial connection factory must receive the selected driverTa5d6ff"Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff0Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72falseTb4b4b4) Tb4b4b4}
Tb4b4b4} Tff7b72finally Tb4b4b4{
Te6edf3releaseCreationTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3transportScopeTb4b4b4.Te6edf3cancelTb4b4b4(Tb4b4b4)
Te6edf3executorTb4b4b4.Te6edf3shutdownNowTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`close waits for wake IO then revokes without publishing connected`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runBlockingTff7b72<Tffa657UnitTff7b72> Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Tff7b72val Te6edf3wakeWriteEntered Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Tff7b72val Te6edf3releaseWakeWrite Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Tff7b72val Te6edf3closeEntered Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3serialConnectionListenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3sendBytesTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3calls
Tb4b4b4{
Te6edf3wakeWriteEnteredTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3checkTb4b4b4(Te6edf3releaseWakeWriteTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)
Tb4b4b4}
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3closeEnteredTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4) Tb4b4b4}
Tff7b72val Te6edf3transportScope Tff7b72= Te6edf3CoroutineScopeTb4b4b4(Te6edf3SupervisorJobTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3DispatchersTb4b4b4.Te6edf3DefaultTb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createTransportTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3transportScopeTb4b4b4)
Tff7b72val Te6edf3executor Tff7b72= Te6edf3ExecutorsTb4b4b4.Te6edf3newFixedThreadPoolTb4b4b4(T79c0ff2Tb4b4b4)
Tff7b72try Tb4b4b4{
Tff7b72val Te6edf3startFuture Tff7b72= Te6edf3executorTb4b4b4.Te6edf3submit Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3assertTrueTb4b4b4(
Te6edf3wakeWriteEnteredTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffconnected callback should enter wake I/OTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3assertFalseTb4b4b4(
Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffordinary writes must remain closed until wake I/O completesTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tff7b72val Te6edf3closeFuture Tff7b72= Te6edf3executorTb4b4b4.Te6edf3submit Tb4b4b4{ Te6edf3runBlocking Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}
Te6edf3assertFalseTb4b4b4(
Te6edf3closeEnteredTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3NOT_YET_WINDOW_MSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3MILLISECONDSTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffclose must not close the connection while admitted wake I/O is still runningTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3releaseWakeWriteTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3startFutureTb4b4b4.Te6edf3getTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3closeFutureTb4b4b4.Te6edf3getTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3closeEnteredTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff0Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3callbackTb4b4b4.Te6edf3onConnectTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4} Tff7b72finally Tb4b4b4{
Te6edf3releaseWakeWriteTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3transportScopeTb4b4b4.Te6edf3cancelTb4b4b4(Tb4b4b4)
Te6edf3executorTb4b4b4.Te6edf3shutdownNowTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`unexpected wake failure closes the connection without publishing connected`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3serialConnectionListenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3sendBytesTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3throws Te6edf3UnsupportedOperationExceptionTb4b4b4(Ta5d6ff"Ta5d6ffwake failedTa5d6ff"Tb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createTransportTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3backgroundScopeTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff0Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3callbackTb4b4b4.Te6edf3onConnectTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3callbackTb4b4b4.Te6edf3onDisconnectTb4b4b4(Te6edf3isPermanent Tff7b72= Tff7b72falseTb4b4b4, Te6edf3errorMessage Tff7b72= Tff7b72nullTb4b4b4, Te6edf3reason Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72falseTb4b4b4) Tb4b4b4}
Te6edf3assertFalseTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`explicit close suppresses a disconnect notification deferred by admitted IO`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3serialConnectionListenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4) Tb4b4b4}
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createTransportTb4b4b4(Te6edf3addressTb4b4b4, Tff7b72thisTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3serialConnectionListenerTb4b4b4.Te6edf3onDisconnectedTb4b4b4(Tff7b72nullTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff0Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3callbackTb4b4b4.Te6edf3onDisconnectTb4b4b4(Te6edf3isPermanent Tff7b72= Tff7b72falseTb4b4b4, Te6edf3errorMessage Tff7b72= Tff7b72nullTb4b4b4, Te6edf3reason Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72falseTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`close drains an admitted queued write before closing its connection`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runBlockingTff7b72<Tffa657UnitTff7b72> Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Tff7b72val Te6edf3writeEntered Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Tff7b72val Te6edf3releaseWrite Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Tff7b72val Te6edf3closeEntered Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3serialConnectionListenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4) Tb4b4b4}
Tff7b72val Te6edf3transportScope Tff7b72= Te6edf3CoroutineScopeTb4b4b4(Te6edf3SupervisorJobTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3DispatchersTb4b4b4.Te6edf3DefaultTb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createTransportTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3transportScopeTb4b4b4)
Tff7b72val Te6edf3executor Tff7b72= Te6edf3ExecutorsTb4b4b4.Te6edf3newSingleThreadExecutorTb4b4b4(Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3sendBytesTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3calls
Tb4b4b4{
Te6edf3writeEnteredTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3checkTb4b4b4(Te6edf3releaseWriteTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)
Tb4b4b4}
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3closeEnteredTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4) Tb4b4b4}
Tff7b72try Tb4b4b4{
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4, T79c0ff2Tb4b4b4, T79c0ff3Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3assertTrueTb4b4b4(
Te6edf3writeEnteredTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffthe admitted write should reach the connectionTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tff7b72val Te6edf3closeFuture Tff7b72= Te6edf3executorTb4b4b4.Te6edf3submit Tb4b4b4{ Te6edf3runBlocking Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}
Te6edf3assertFalseTb4b4b4(
Te6edf3closeEnteredTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3NOT_YET_WINDOW_MSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3MILLISECONDSTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffclose must wait for the admitted write handoffTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3releaseWriteTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3closeFutureTb4b4b4.Te6edf3getTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3closeEnteredTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)
Tb4b4b4} Tff7b72finally Tb4b4b4{
Te6edf3releaseWriteTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3transportScopeTb4b4b4.Te6edf3cancelTb4b4b4(Tb4b4b4)
Te6edf3executorTb4b4b4.Te6edf3shutdownNowTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`stale terminal callbacks do not tear down a replacement connection`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Tff7b72val Te6edf3connections Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3RecordingSerialConnectionTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createRecordingTransportTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3connectionsTb4b4b4, Tff7b72thisTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3connectionsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3listenerTb4b4b4.Te6edf3onDisconnectedTb4b4b4(Tff7b72nullTb4b4b4)
Te6edf3assertFalseTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff2Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3callbackTb4b4b4.Te6edf3onDisconnectTb4b4b4(Te6edf3isPermanent Tff7b72= Tff7b72falseTb4b4b4, Te6edf3errorMessage Tff7b72= Tff7b72nullTb4b4b4, Te6edf3reason Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4}
Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Tff7b72falseTb4b4b4)Tb4b4b4, Te6edf3connectionsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3closeRequestsTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff3Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3connectionsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3listenerTb4b4b4.Te6edf3onDisconnectedTb4b4b4(Te6edf3IllegalStateExceptionTb4b4b4(Ta5d6ff"Ta5d6fflate disconnectTa5d6ff"Tb4b4b4)Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff4Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3connectionsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3listenerTb4b4b4.Te6edf3onMissingPermissionTb4b4b4(Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff5Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)
T8b949e// Mokkery verifies only calls not consumed by the earlier assertion, so stale callbacks add zero new events.
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff0Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3callbackTb4b4b4.Te6edf3onDisconnectTb4b4b4(Te6edf3isPermanent Tff7b72= Tff7b72falseTb4b4b4, Te6edf3errorMessage Tff7b72= Tff7b72nullTb4b4b4, Te6edf3reason Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4}
Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Tff7b72falseTb4b4b4)Tb4b4b4, Te6edf3connectionsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3closeRequestsTb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3connectionsTff7b72[T79c0ff1Tff7b72]Tb4b4b4.Te6edf3closeRequestsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffstale callbacks must not close the replacementTa5d6ff"Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Tff7b72trueTb4b4b4)Tb4b4b4, Te6edf3connectionsTff7b72[T79c0ff1Tff7b72]Tb4b4b4.Te6edf3closeRequestsTb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`start during connection cleanup opens a replacement after cleanup completes`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Tff7b72val Te6edf3connections Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3RecordingSerialConnectionTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createRecordingTransportTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3connectionsTb4b4b4, Tff7b72thisTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3connectionsTb4b4b4.Te6edf3singleTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3listenerTb4b4b4.Te6edf3onDisconnectedTb4b4b4(Tff7b72nullTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3connectionsTb4b4b4.Te6edf3sizeTb4b4b4, Ta5d6ff"Ta5d6ffreplacement must wait for physical cleanupTa5d6ff"Tb4b4b4)
Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff2Tb4b4b4, Te6edf3connectionsTb4b4b4.Te6edf3sizeTb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff2Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Tff7b72trueTb4b4b4)Tb4b4b4, Te6edf3connectionsTff7b72[T79c0ff1Tff7b72]Tb4b4b4.Te6edf3closeRequestsTb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`repeated start cannot replace an active connection generation`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Tff7b72val Te6edf3connections Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3RecordingSerialConnectionTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createRecordingTransportTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3connectionsTb4b4b4, Tff7b72thisTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3connectionsTb4b4b4.Te6edf3sizeTb4b4b4, Ta5d6ff"Ta5d6ffrepeated start must not open a throwaway USB generationTa5d6ff"Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(Te6edf3emptyListTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3connectionsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3closeRequestsTb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff2Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Tff7b72trueTb4b4b4)Tb4b4b4, Te6edf3connectionsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3closeRequestsTb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`concurrent close callers await the same physical teardown`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runBlockingTff7b72<Tffa657UnitTff7b72> Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Tff7b72val Te6edf3closeEntered Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Tff7b72val Te6edf3releaseClose Tff7b72= Te6edf3CountDownLatchTb4b4b4(T79c0ff1Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3serialConnectionListenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4} Te6edf3calls
Tb4b4b4{
Te6edf3closeEnteredTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3checkTb4b4b4(Te6edf3releaseCloseTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)
Tb4b4b4}
Tff7b72val Te6edf3transportScope Tff7b72= Te6edf3CoroutineScopeTb4b4b4(Te6edf3SupervisorJobTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3DispatchersTb4b4b4.Te6edf3DefaultTb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createTransportTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3transportScopeTb4b4b4)
Tff7b72val Te6edf3executor Tff7b72= Te6edf3ExecutorsTb4b4b4.Te6edf3newFixedThreadPoolTb4b4b4(T79c0ff2Tb4b4b4)
Tff7b72try Tb4b4b4{
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3first Tff7b72= Te6edf3executorTb4b4b4.Te6edf3submit Tb4b4b4{ Te6edf3runBlocking Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}
Te6edf3assertTrueTb4b4b4(Te6edf3closeEnteredTb4b4b4.Te6edf3awaitTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)Tb4b4b4)
Tff7b72val Te6edf3second Tff7b72= Te6edf3executorTb4b4b4.Te6edf3submit Tb4b4b4{ Te6edf3runBlocking Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}
Te6edf3assertFailsWithTff7b72<Te6edf3TimeoutExceptionTff7b72> Tb4b4b4{ Te6edf3secondTb4b4b4.Te6edf3getTb4b4b4(Te6edf3NOT_YET_WINDOW_MSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3MILLISECONDSTb4b4b4) Tb4b4b4}
Te6edf3releaseCloseTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3firstTb4b4b4.Te6edf3getTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)
Te6edf3secondTb4b4b4.Te6edf3getTb4b4b4(Te6edf3COMPLETION_WINDOW_SECONDSTb4b4b4, Te6edf3TimeUnitTb4b4b4.Te6edf3SECONDSTb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4}
Tb4b4b4} Tff7b72finally Tb4b4b4{
Te6edf3releaseCloseTb4b4b4.Te6edf3countDownTb4b4b4(Tb4b4b4)
Te6edf3transportScopeTb4b4b4.Te6edf3cancelTb4b4b4(Tb4b4b4)
Te6edf3executorTb4b4b4.Te6edf3shutdownNowTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`legacy selected address resolves the sole USB serial device`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3selectedAddress Tff7b72= Ta5d6ff"Ta5d6fflegacy-path-addressTa5d6ff"
Tff7b72val Te6edf3soleDevice Tff7b72= Te6edf3mockTff7b72<Te6edf3UsbSerialDriverTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3connections Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3RecordingSerialConnectionTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3transport Tff7b72=
Te6edf3createRecordingTransportTb4b4b4(
Te6edf3address Tff7b72= Te6edf3selectedAddressTb4b4b4,
Te6edf3connections Tff7b72= Te6edf3connectionsTb4b4b4,
Te6edf3scope Tff7b72= Te6edf3backgroundScopeTb4b4b4,
Te6edf3devices Tff7b72= Te6edf3mapOfTb4b4b4(Ta5d6ff"Ta5d6ffstable-usb-keyTa5d6ff" Te6edf3to Te6edf3soleDeviceTb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Te6edf3soleDeviceTb4b4b4)
Te6edf3assertEqualsTb4b4b4(
T79c0ff1Tb4b4b4,
Te6edf3connectionsTb4b4b4.Te6edf3sizeTb4b4b4,
Ta5d6ff"Ta5d6ffa legacy address may self-heal when exactly one USB serial device is presentTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`ambiguous missing selected device never falls back to another USB serial device`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3selectedAddress Tff7b72= Ta5d6ff"Ta5d6ffselected-deviceTa5d6ff"
Tff7b72val Te6edf3connections Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3RecordingSerialConnectionTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3transport Tff7b72=
Te6edf3createRecordingTransportTb4b4b4(
Te6edf3address Tff7b72= Te6edf3selectedAddressTb4b4b4,
Te6edf3connections Tff7b72= Te6edf3connectionsTb4b4b4,
Te6edf3scope Tff7b72= Te6edf3backgroundScopeTb4b4b4,
Te6edf3devices Tff7b72= Te6edf3mapOfTb4b4b4(Ta5d6ff"Ta5d6ffother-aTa5d6ff" Te6edf3to Te6edf3mockTff7b72<Te6edf3UsbSerialDriverTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffother-bTa5d6ff" Te6edf3to Te6edf3mockTff7b72<Te6edf3UsbSerialDriverTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3connectionsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffan ambiguous selected-address miss must not open an unrelated serial deviceTa5d6ff"Tb4b4b4)
Te6edf3assertFalseTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`start after close cannot reopen a serial transport`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3serialConnectionListenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4) Tb4b4b4}
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createTransportTb4b4b4(Te6edf3addressTb4b4b4, Tff7b72thisTb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3assertFalseTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`send is rejected before connection and after close`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffserial-deviceTa5d6ff"
Tff7b72val Te6edf3transport Tff7b72= Te6edf3createTransportTb4b4b4(Te6edf3addressTb4b4b4, Tff7b72thisTb4b4b4)
Te6edf3assertFalseTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3serialConnectionListenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Te6edf3assertRequestedDriverTb4b4b4(Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff2Tb4b4b4)Tb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffan established connection must accept the handoffTa5d6ff"Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3serialConnectionTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3assertFalseTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff3Tb4b4b4)Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72class T56d364RecordingSerialConnectionTb4b4b4(Tff7b72val Te6edf3listenerTb4b4b4: Te6edf3SerialConnectionListenerTb4b4b4) Tb4b4b4: Te6edf3SerialConnection Tb4b4b4{
Tff7b72val Te6edf3closeRequests Tff7b72= Te6edf3mutableListOfTff7b72<Tffa657BooleanTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72override Tff7b72fun Td2a8ffconnectTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3listenerTb4b4b4.Te6edf3onConnectedTb4b4b4(Tb4b4b4)
Tff7b72override Tff7b72fun Td2a8ffsendBytesTb4b4b4(Te6edf3bytesTb4b4b4: Te6edf3ByteArrayTb4b4b4) Tff7b72= Tffa657Unit
Tff7b72override Tff7b72fun Td2a8ffcloseTb4b4b4(Te6edf3waitForStoppedTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{
Te6edf3closeRequests Tff7b72+Tff7b72= Te6edf3waitForStopped
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffcloseTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3closeTb4b4b4(Te6edf3waitForStopped Tff7b72= Tff7b72falseTb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72companion Tff7b72object Tb4b4b4{
T8b949e// Negative wall-clock assertions get a generous scheduler margin without slowing successful paths.
Tff7b72const Tff7b72val Te6edf3NOT_YET_WINDOW_MS Tff7b72= T79c0ff5T79c0ff0T79c0ff0L
T8b949e// Positive waits tolerate contended CI scheduling; exceeding this bound indicates a real hang.
Tff7b72const Tff7b72val Te6edf3COMPLETION_WINDOW_SECONDS Tff7b72= T79c0ff1T79c0ff0L
Tb4b4b4}
Tb4b4b4}
Served by rngit 1.5.0 - Generated in 0.19s